


from utils import *
from top.wardyan.core.utils.common import *

import sys
import os




args = sys.argv[1:]
print(current_timestamp(), "调用参数", args)

if len(args) == 0:
    print(current_timestamp(), "未指定参数，退出")
    sys.exit(0)

datatype = args[0]
dt = args[1]



## 步骤
id = init_clean_main(datatype, dt)
print(current_timestamp(), "生成主表记录", id)
## 从配置文件中初始化清理项目明细,包括主表和明细表

print(current_timestamp(),"从配置文件中初始化清理项目明细,包括主表和明细表", id)
init_clean_items(id)

## 初步统计每个数据表的行数
print(current_timestamp(),"初步统计每个数据表的行数", id)
init_clean_init_rows(id)

## 统计每个批号在每个数据表的最大最小ID
print(current_timestamp(),"统计每个批号在每个数据表的最大最小ID", id)
init_clean_count(id)

## 生成SQL
print(current_timestamp(),"生成SQL...", id)
init_buildsql(id)

## 执行

print(current_timestamp(),"完成生成SQL", id)